package com.deep.rocket;

import com.deep.rocket.producer.message.MySink;
import com.deep.rocket.producer.message.MySource;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.cloud.stream.messaging.Source;


/**
 * 记得添加@EnableBinding注解指定消息信道
 * Sink.class 表示信道 input , Source.class 表示信道 output
 * 这两个分别与application.yml中的spring.cloud.stream.bindings.input和spring.cloud.stream.bindings.output对应
 * 如果信道名称换成是sender和receiver，就得配置spring.cloud.stream.bindings.sender和spring.cloud.stream.bindings.receiver
 */
@EnableBinding(value = {Sink.class, Source.class, MySink.class, MySource.class})
@SpringBootApplication
public class RocketStreamApplication {
    // 18545577624
    public static void main(String[] args) {
        SpringApplication.run(RocketStreamApplication.class, args);
    }

}
